Details
-
Bug
-
Status: Resolved
-
Critical
-
Resolution: Fixed
-
None
-
None
-
None
Description
1. TTransportException thrown when trying to visit topology page in UI:
When trying to access the topology page on the storm ui, exceptions are thrown.
Visiting a topology page displays a TTransportException.
The cause can be seen in nimbus.log:
java.lang.IllegalArgumentException: Don't know how to create ISeq from: clojure.core$PLUS
at clojure.lang.RT.seqFrom(RT.java:528)
at clojure.lang.RT.seq(RT.java:509)
at clojure.core$seq__4128.invoke(core.clj:137)
at clojure.core.protocols$seq_reduce.invoke(protocols.clj:26)
at clojure.core.protocols$fn__6500.invoke(protocols.clj:83)
at clojure.core.protocols$fn_6452$G6447_6465.invoke(protocols.clj:13)
at clojure.core$reduce.invoke(core.clj:6515)
at org.apache.storm.stats$agg_pre_merge_topo_page_bolt.invoke(stats.clj:564)
at org.apache.storm.stats$agg_topo_exec_stats_STAR_.invoke(stats.clj:744)
at org.apache.storm.stats$fn__1257.invoke(stats.clj:792)
at clojure.lang.MultiFn.invoke(MultiFn.java:243)
at clojure.core$partial$fn__4529.invoke(core.clj:2501)
at clojure.core.protocols$fn__6523.invoke(protocols.clj:167)
at clojure.core.protocols$fn_6478$G6473_6487.invoke(protocols.clj:19)
at clojure.core.protocols$seq_reduce.invoke(protocols.clj:31)
at clojure.core.protocols$fn__6506.invoke(protocols.clj:101)
at clojure.core.protocols$fn_6452$G6447_6465.invoke(protocols.clj:13)
at clojure.core$reduce.invoke(core.clj:6519)
at org.apache.storm.stats$aggregate_topo_stats.invoke(stats.clj:874)
at org.apache.storm.stats$agg_topo_execs_stats.invoke(stats.clj:1037)
at org.apache.storm.daemon.nimbus$fn_4817$exec_fn2064auto$reify_4846.getTopologyPageInfo(nimbus.clj:2105)
at org.apache.storm.generated.Nimbus$Processor$getTopologyPageInfo.getResult(Nimbus.java:3800)
at org.apache.storm.generated.Nimbus$Processor$getTopologyPageInfo.getResult(Nimbus.java:3784)
at org.apache.storm.thrift.ProcessFunction.process(ProcessFunction.java:39)
at org.apache.storm.thrift.TBaseProcessor.process(TBaseProcessor.java:39)
at org.apache.storm.security.auth.SimpleTransportPlugin$SimpleWrapProcessor.process(SimpleTransportPlugin.java:158)
at org.apache.storm.thrift.server.AbstractNonblockingServer$FrameBuffer.invoke(AbstractNonblockingServer.java:518)
at org.apache.storm.thrift.server.Invocation.run(Invocation.java:18)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
2. Exception thrown in supervisor:
java.lang.ClassCastException: java.lang.Integer cannot be cast to java.lang.String
at org.apache.storm.daemon.supervisor$create_artifacts_link.invoke(supervisor.clj:1083)
at org.apache.storm.daemon.supervisor$fn__7494.invoke(supervisor.clj:1180)
at clojure.lang.MultiFn.invoke(MultiFn.java:251)
at org.apache.storm.daemon.supervisor$get_valid_new_worker_ids$iter_70817085$fn_7086.invoke(supervisor.clj:393)
at clojure.lang.LazySeq.sval(LazySeq.java:40)
at clojure.lang.LazySeq.seq(LazySeq.java:49)
at clojure.lang.RT.seq(RT.java:507)
at clojure.core$seq__4128.invoke(core.clj:137)
at clojure.core$dorun.invoke(core.clj:3009)
at clojure.core$doall.invoke(core.clj:3025)
at org.apache.storm.daemon.supervisor$get_valid_new_worker_ids.invoke(supervisor.clj:380)
at org.apache.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:447)
at clojure.core$partial$fn__4527.invoke(core.clj:2492)
at org.apache.storm.event$event_manager$fn__6781.invoke(event.clj:40)
at clojure.lang.AFn.run(AFn.java:22)
at java.lang.Thread.run(Thread.java:745)
3. Exception in UI:
java.lang.ClassCastException: java.lang.String cannot be cast to java.lang.Number
at org.apache.storm.ui.core$worker_log_link.invoke(core.clj:150)
at org.apache.storm.ui.core$get_error_json.invoke(core.clj:531)
at org.apache.storm.ui.core$fn__11747.invoke(core.clj:553)
at clojure.lang.MultiFn.invoke(MultiFn.java:238)
at clojure.core$partial$fn__4529.invoke(core.clj:2500)
at clojure.core$map$fn__4553.invoke(core.clj:2624)
at clojure.lang.LazySeq.sval(LazySeq.java:40)
at clojure.lang.LazySeq.seq(LazySeq.java:49)
at clojure.lang.RT.seq(RT.java:507)
at clojure.lang.SeqIterator.hasNext(SeqIterator.java:38)